package com.xuecheng.media.service.jobhandler;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;


@Component
@Slf4j
public class SampleXxlJob { //这个是任务类，它是spring的一个bean
    // 是具体的任务方法
    // demoJobHandler：任务名称
    // 任务也是需要在调度中心去注册
    @XxlJob("demoJobHandler")
    public void demoJobHandler() throws Exception {
        System.out.println("处理视频......");
        // 分片参数
        for (int i=0;i<5;i++){
            XxlJobHelper.log("beat at:"+i);
            TimeUnit.SECONDS.sleep(2);
        }
//        int shardIndex = XxlJobHelper.getShardIndex();
//        int shardTotal = XxlJobHelper.getShardTotal();
//        log.info("分片参数：当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);
//        log.info("开始执行第"+shardIndex+"批任务");
    }




}
